from kafka import KafkaConsumer

consumer = KafkaConsumer('t_sce_crossquota', bootstrap_servers = ['10.2.111.56:9092', '10.2.111.51:9092', '10.2.111.60:9092'])

for msg in consumer:
    print(msg)